/**
 * 该文件可自行根据业务逻辑进行调整
 * @description 该文件用于创建全局请求客户端，用于发送请求，默认返回数据中的 data 字段
 */
import type { RequestClientOptions } from '@vben/request';

import { useAppConfig } from '@vben/hooks';
import { preferences } from '@vben/preferences';
import {
  authenticateResponseInterceptor,
  defaultResponseInterceptor,
  errorMessageResponseInterceptor,
  RequestClient,
} from '@vben/request';
import { useAccessStore } from '@vben/stores';

import { message } from 'ant-design-vue';

import { useAuthStore } from '#/store';
import { formatToken } from '#/utils/auth';

import { refreshTokenApi } from './core';

/**
 * 全局请求客户端选项
 * @description 全局请求客户端选项，用于创建全局请求客户端
 */
const { apiURL } = useAppConfig(import.meta.env, import.meta.env.PROD);
// 修正API基础URL端口以匹配后端服务
const baseURL = apiURL || 'http://localhost:8000';

/**
 * 创建请求客户端
 * @description 创建一个请求客户端，用于发送请求，默认返回数据中的 data 字段
 * @param options 请求客户端选项
 */
function createRequestClient(options?: RequestClientOptions) {
  const client = new RequestClient({ baseURL, ...options });

  /**
   * 重新认证逻辑
   * @description 重新认证逻辑，用于重新获取 access token
   */
  async function doReAuthenticate() {
    console.warn('Access token or refresh token is invalid or expired. ');
    const accessStore = useAccessStore();
    const authStore = useAuthStore();
    accessStore.setAccessToken(null);
    if (
      preferences.app.loginExpiredMode === 'modal' &&
      accessStore.isAccessChecked
    ) {
      accessStore.setLoginExpired(true);
    } else {
      await authStore.logout();
    }
  }

  /**
   * 刷新token逻辑
   * @description 刷新token逻辑，用于重新获取 access token
   */
  async function doRefreshToken() {
    const accessStore = useAccessStore();
    const resp = await refreshTokenApi();
    const newToken = resp.data;
    accessStore.setAccessToken(newToken);
    return newToken;
  }

  /**
   * 请求头处理
   * @description 请求头处理，用于在请求头中添加 access token 和语言
   */
  client.addRequestInterceptor({
    fulfilled: async (config) => {
      const accessStore = useAccessStore();

      config.headers.Authorization = formatToken(accessStore.accessToken);
      config.headers['Accept-Language'] = preferences.app.locale;
      return config;
    },
  });

  /**
   * 响应拦截器1：处理返回的响应数据格式
   * @description 处理返回的响应数据格式，默认返回数据中的 data 字段
   */
  client.addResponseInterceptor(
    defaultResponseInterceptor({
      codeField: 'code',
      dataField: 'data',
      successCode: 0,
    }),
  );

  /**
   * 响应拦截器2：token过期的处理
   * @description token过期的处理，用于处理 token 过期的情况，重新获取 access token
   */
  client.addResponseInterceptor(
    authenticateResponseInterceptor({
      client,
      doReAuthenticate,
      doRefreshToken,
      enableRefreshToken: preferences.app.enableRefreshToken,
      formatToken,
    }),
  );

  /**
   * 响应拦截器3：通用的错误处理
   * @description 通用的错误处理，用于处理请求返回的错误信息，默认使用 message.error 提示错误信息
   */
  client.addResponseInterceptor(
    errorMessageResponseInterceptor((msg: string, error) => {
      // 这里可以根据业务进行定制,你可以拿到 error 内的信息进行定制化处理，根据不同的 code 做不同的提示，而不是直接使用 message.error 提示 msg
      // 当前mock接口返回的错误字段是 error 或者 message
      const responseData = error?.response?.data ?? {};
      const errorMessage = responseData?.error ?? responseData?.message ?? '';
      // 如果没有错误信息，则会根据状态码进行提示
      message.error(errorMessage || msg);
    }),
  );

  return client;
}

/**
 * 全局请求客户端
 * @description 全局请求客户端，用于发送请求，默认返回数据中的 data 字段
 * 用于发送普通的请求，例如获取列表、获取详情等
 */
export const requestClient = createRequestClient({
  responseReturn: 'data',
});

/**
 * 基础请求客户端
 * @description 基础请求客户端，用于发送请求，不返回数据中的 data 字段
 * 用于发送需要原始响应数据的请求，例如文件下载
 */
export const baseRequestClient = new RequestClient({ baseURL });
